#!/usr/bin/python3

import pymysql

#打开数据库连接
db = pymysql.connect("localhost", "tushare", "tushare123", "tushare")

#使用 cursor() 方法创建一个游标对象 cursor
cursor = db.cursor()

#使用 execute() 方法执行 SQL查询
verson = cursor.execute("SELECT VERSION()")
print(verson)

#使用 fetchone() 方法获取单条数据。
data = cursor.fetchone()

print("Database version : %s" %data)

stockCode = input("请输入股票代码:\n")
date = input("输入日期:\n")

insql = "INSERT INTO stock_date (`code`, `date`) VALUES ('%s', '%s')" % (stockCode, date)

# try:
# cursor.execute(insql)
# db.commit()
# except:
    # print("插入失败: %s" % sys.exc_info()[0])
    # db.rollback()

selsql = "SELECT * FROM stock_date"
cursor.execute(selsql)
results = cursor.fetchall()
for row in results:
    code = row[1]
    date = row[2]
    #打印结果
    print("fname=%s,lname=%s" % (code, date))

#关闭数据库连接
db.close()